package com.fz.consumer.listeners;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Map;
import java.util.Objects;

@Component
@Slf4j
public class MqListener5 {
    @RabbitListener(queues = "object.queue")
    public void listenObjectQueue(Map<String, Objects> msg){
        log.info("对象消息：{}",msg);
    }
}
